package ExperimentSix.ExecutorService;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPool {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // 提交多个任务到线程池
        for (int i = 1; i <= 5; i++) {
            Task task = new Task(i);
            executorService.submit(task); // 提交任务到线程池
        }

        // 关闭线程池，不再接受新的任务，已提交的任务将继续执行
        executorService.shutdown();
        // 等待所有任务完成
        while (!executorService.isTerminated()) {
            // 可以做其他事情
        }
        System.out.println("所有任务已完成");
    }
}